package com.example

import org.apache.flink.api.scala._

object UnionDemo1 {
  def main(args: Array[String]): Unit = {
    // 批处理
    val env = ExecutionEnvironment.getExecutionEnvironment

    val oneDs: DataSet[String]= env.fromCollection(List("hadoop","java","flink"))
    val twoDs: DataSet[String]= env.fromCollection(List("hadoop","1","2"))

    oneDs.union(twoDs).print()



  }

//  leftjon outerjon rightjoin join







}
